package com.eascs.spider.ant.common.kafka;

import java.util.Map;

import org.apache.kafka.common.serialization.Deserializer;

import com.eascs.spider.ant.common.util.ObjectUtil;

public class DecodeingKafka implements Deserializer<Object>{
	
	@Override  
    public void configure(Map<String, ?> configs, boolean isKey) {  
    }  
  
    @Override  
    public Object deserialize(String topic, byte[] data) {  
        return ObjectUtil.ByteToObject(data);  
    }  
  
    @Override  
    public void close() {  
          
    } 
}
